package com.ydl.learning.flink.demo.pipeline.java;

import org.apache.flink.streaming.api.datastream.DataStream;

/**
 * 核心的功能处理接口，接收前一个处理阶段的输入流，并按业务逻辑完成计算将结果输入到下一个阶段
 */
public interface Process<T> extends BaseProcedure {

  /**
   *
   */
  void setTable(DataStream<T> result);

  /**
   *
   */
  DataStream<T> run();

}